package com.ayu.shortlink.admin.common.constant;

import lombok.Data;

/**
 * RocketMQ的常量
 */
@Data
public class RocketMQConstant {
    /**
     * 立刻执行任务的主题
     */
    public final static String TOPIC_EXECUTOR_IMMEDIATELY_TASK = "short-link_rocketmq-topic_executor-immediately-task";

    /**
     * 延迟执行任务的主题
     */
    public final static String TOPIC_EXECUTOR_DELAY_TASK = "short-link_rocketmq-topic_executor-delay-task";

    /**
     * 延迟执行任务改变状态消费者组
     */
    public final static String GROUP_DELAY_EXECUTOR_TASK_STATUS_CHANGE = "short-link_rocketmq-group_delay-executor-task-status-change";

    /**
     * 通知各engine服务器去删除空缓存的主题
     */
    public final static String TOPIC_COUPON_DELETE_EMPTY_CACHE = "short-link_rocketmq-topic_coupon-delete-empty-cache";

    /**
     * 用户获取优惠券的主题
     */
    public final static String TOPIC_USER_GAIN_COUPON = "short-link_rocketmq-topic_user-gain-coupon";

    /**
     * 用户获取优惠券的主题
     */
    public final static String GROUP_USER_GAIN_COUPON = "short-link_rocketmq-group_user-gain-coupon";
}
